[SPARK-4946] [CORE] Using AkkaUtils.askWithReply in MapOutputTracker.askTracker to reduce the chance of the communicating problem#3785
Conversation
…askTracker to reduce the chance of the communicating problem
|
Test build #24765 has started for PR 3785 at commit
|
|
Test build #24765 has finished for PR 3785 at commit
|
|
Test PASSed. |
|
On the surface, this seems like an okay change. I wonder whether this retry logic could have unexpected consequences. Let me try to reason it out:
In the common cases, though, this seems fine, even if the map output statuses are missing (since it won't introduce a bunch of futile retries). Therefore, I think we should pull this in; I don't know if this fixes an actual bug, but it seems like it could make things more robust. |
|
Alright, I'm going to merge this into |
Using AkkaUtils.askWithReply in MapOutputTracker.askTracker to reduce the chance of the communicating problem